package com.源码分析;

import reactor.core.publisher.Flux;

public class ThenManyDemo {

	// Mono和Flux流有then、thenMany、thenEmpty操作符，他们在上游流完成时完成，这些操作符忽略传入元素，仅重放完成或错误信号，上游流完成处理后，这些操作符可用于触发新流
	public static void main(String[] args) {
		Flux.just(1, 2, 3).thenMany(Flux.just(4, 5)).subscribe(System.out::println);// 只打印4, 5
	}

}
